package Utils
import org.apache.spark.sql.{Dataset, SparkSession}
object dfCreation {
  val spark = SparkSession.builder().appName("column").master("local[*]").getOrCreate()
  import spark.implicits._
  val personDF: Dataset[Person] = Seq(Person("zhangsan", 12), Person("zhangsan", 8), Person("lisi", 15)).toDS()

}

case class Person(str: String, i: Int)
